package cn.iocoder.yudao.module.bpm.mq;

import com.xueyi.common.message.mq.callback.message.CallbackChannelMessage;
import com.xueyi.common.message.mq.pubsub.AbstractChannelMessageListener;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

@Component
@Slf4j
public class CallbackChannelConsumer extends AbstractChannelMessageListener<CallbackChannelMessage> {
//public class CallbackChannelConsumer {

    /*@Resource
    private DeptService deptService;*/

    @Override
    public void onMessage(CallbackChannelMessage message) {
        log.info("[workflow onMessage][收到 workflow callback消息]  伟大的超哥万岁！" + message.getMessage());
        System.out.println("[workflow onMessage][收到 workflow callback消息]  伟大的超哥万岁！" + message.getMessage());
        //deptService.initLocalCache();
    }

}
